﻿using MassTransit;
using MQNamespace;
using System;

namespace Athena.Performance.Models.MQ
{
    public abstract class BaseRequest : IBaseRequestModel, IBaseRequest
    {
        public Guid? CorrelationId
        {
            get;
        }

        public DateTime TimeStamp
        {
            get;
        }


        public BaseRequest(Guid? correlationId)
        {
            CorrelationId = correlationId;
            TimeStamp = DateTime.Now;
        }

        public abstract void CreateClient(IBusControl busControl, Uri uri);
    }
}
